package com.base.im.server.netty.echo;

import io.netty.channel.Channel;

public class MsgTestThread  implements Runnable{
	
	
	public static void main(String[] args) {
		
		while(true){
			
			Channel session = EchoSession.getSession(100);
			while(null != session){
				session.writeAndFlush("服务端发送给客户端");
			}
		}
		
		
		
	}

	@Override
	public void run() {
		
		while(true){
			
			Channel session = EchoSession.getSession(100);
			while(null != session){
				session.writeAndFlush("服务端发送给客户端");
			}
		}
		
	}
	
	
}
